package com.xinqing.bigdata.flink.datastream.selector;


import com.xinqing.bigdata.flink.datastream.model.Student;
import org.apache.flink.api.java.functions.KeySelector;


/**
 * @Author:CHQ
 * @Date:2021/4/21 10:45
 * @Description
 */
public class MySelector implements KeySelector<Student, String> {
    @Override
    public String getKey(Student value) throws Exception {
        return value.getSid();
    }
}
